package disruptor;

import com.lmax.disruptor.WorkHandler;

public class DisruptorWorkHandler implements WorkHandler<DisruptorEvent> {
    Integer num = 0;

    public DisruptorWorkHandler(Integer num) {
        this.num = num;
    }

    @Override
    public void onEvent(DisruptorEvent event) {
        System.err.println("消费者：" + num + " | "  + event.toString());
    }
}
